-
Notifications
You must be signed in to change notification settings - Fork 596
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
feat: Introduce table resize plan for scaling. #14235
Conversation
b31a26f
to
33dbda5
Compare
Signed-off-by: Shanicky Chen <[email protected]>
33dbda5
to
670c33b
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM, let's see whether if using sorted pu in scheduler can fix the in-consistency issue.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
FixedParallelism fixed = 1; | ||
AutoParallelism auto = 2; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Would you mind adding some comments to describe them? For example, the respective behavior when auto scaling is on/off.
// We redistribute parallel units (which will be ensembles in the future) through a simple consistent hashing ring. | ||
// Note that we have added some simple logic here to ensure the consistency of the ratio between each slot, | ||
// especially when equal division is needed. | ||
pub fn schedule_units_for_slots( |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
What about extracting this utility into separate files?
I hereby agree to the terms of the RisingWave Labs, Inc. Contributor License Agreement.
What's changed and what's your intention?
first part of #13954
Checklist
./risedev check
(or alias,./risedev c
)